package pipline

import (
	"database/sql"
	"github.com/gogf/gf/frame/g"
	"main/model"
)

func SavePost(data *model.PostInfo) error {
	// 查询一次
	old := &model.PostInfo{}
	err := g.DB().Table(`postInfo`).Struct(old, `Ref_Id=?`, data.RefId)
	//新增
	if err == sql.ErrNoRows {
		_, err = g.DB().Table(`postInfo`).FieldsEx(``).Insert(data)
	} else if err == nil {
		//update
		_, err = g.DB().Table(`postInfo`).FieldsEx(`id`).Update(data, "id=?", old.Id)
	}
	return err
}
